packages/durably/src/durably.ts (1)

1045-1046: lastPurgeAt がローカル変数に変更された点について

lastPurgeAt が DurablyState から削除され、createDurably のローカル変数になりました。これは実装詳細を隠蔽する良い変更ですが、テストコメント（purge.shared.ts の 247-248 行、261-263 行）で lastPurgeAt への言及が残っています。テストコメントは内部状態を説明するためのものなので問題ありませんが、将来のメンテナ向けにコメントが内部実装を参照していることを認識しておいてください。

🤖 Prompt for AI Agents

Verify each finding against the current code and only fix it if needed.

In `@packages/durably/src/durably.ts` around lines 1045 - 1046, Tests still
mention the internal variable lastPurgeAt which was removed from DurablyState
and made a local variable inside createDurably; update the test comments in
purge.shared.ts (around the existing references) to stop referring to
lastPurgeAt directly — either remove the internal-variable mention or replace it
with a comment that the value is now held internally within createDurably
(DurablyState -> createDurably, lastPurgeAt) so future readers aren’t misled by
implementation details.

packages/durably/src/worker.ts (1)

36-48: onIdle() での例外がポーリングループをクラッシュさせる可能性

onIdle() が例外をスローした場合、poll() 内で捕捉されず、ポーリングループが停止してしまいます。durably.ts 側の runIdleMaintenance は try/catch でラップされていますが、将来的に異なる onIdle コールバックを渡す可能性を考慮すると、ここで防御的に処理することを検討してください。

🛡️ 防御的エラーハンドリングの提案

     const cycle = (async () => {
       const didProcess = await processOne({ workerId: activeWorkerId })
       if (!didProcess && onIdle && running) {
-        await onIdle()
+        try {
+          await onIdle()
+        } catch {
+          // onIdle errors are non-fatal; allow polling to continue
+        }
       }
     })()

🤖 Prompt for AI Agents

Verify each finding against the current code and only fix it if needed.

In `@packages/durably/src/worker.ts` around lines 36 - 48, The polling cycle
currently awaits onIdle() without handling exceptions, so any error thrown by
the onIdle callback can crash the poll loop; inside the anonymous async cycle
(the variable cycle) that calls processOne({ workerId: activeWorkerId }) and
then awaits onIdle(), wrap the onIdle() invocation in a try/catch (or otherwise
guard the await) so exceptions are caught and handled (e.g., log via the same
logger or swallow) and do not escape the cycle; keep the existing inFlight
assignment and finally block behavior unchanged so inFlight is still cleared on
completion.

packages/durably/tests/shared/purge.shared.ts (1)

271-309: テストロジックは正しいが、d.stop()の呼び出しが欠落している可能性あり。

テストロジック自体は正確です：processUntilIdleはmaxRunsに達した場合はreachedIdleがfalseのままでメンテナンスを実行せず、真にアイドル状態になった時のみメンテナンスが実行されることを検証しています。

ただし、Line 308でd.db.destroy()のみ呼び出し、d.stop()を呼び出していません。このテストではd.start()を呼び出していないためワーカーポーリングは起動していませんが、PRの目的によるとstop()は「進行中のアイドルメンテナンスを待機する」ようになっています。processUntilIdle()は内部でメンテナンスを待機するため問題ない可能性がありますが、一貫性のためにd.stop()を追加することを検討してください。

♻️ 一貫性のための修正案

        // Now drain fully (reaches idle) — maintenance runs and purges
        await d.processUntilIdle()
        expect(await d.getRun(run1.id)).toBeNull()

+       await d.stop()
        await d.db.destroy()
      })

🤖 Prompt for AI Agents

Verify each finding against the current code and only fix it if needed.

In `@packages/durably/tests/shared/purge.shared.ts` around lines 271 - 309, The
test omits shutting down the Durably instance: add an explicit await d.stop()
before calling d.db.destroy() so the worker is cleanly stopped and any
in-flight/idle maintenance is awaited; reference the Durably instance methods
processUntilIdle, stop, and the existing d.db.destroy() call and insert the
await d.stop() immediately prior to d.db.destroy().

packages/durably/tests/shared/worker.shared.ts (2)

94-96: 未使用のイベントリスナー

run:leased イベントリスナーが登録されていますが、このテストではジョブがトリガーされないため、このイベントは発火しません。コメントに「worker to process something」とありますが、実際には何も処理されません。

このリスナーは削除するか、テストの意図に沿ったイベント（例: worker:error でメンテナンスエラーを監視）に変更することを検討してください。

🤖 Prompt for AI Agents

Verify each finding against the current code and only fix it if needed.

In `@packages/durably/tests/shared/worker.shared.ts` around lines 94 - 96, The
test registers an unused event listener d.on('run:leased') which never fires;
remove this noop listener or replace it with a meaningful one that matches the
test intent (for example d.on('worker:error') to assert maintenance or error
conditions). Locate the registration of d.on('run:leased') in the test (symbol:
d.on) and either delete that line or change the event name and accompanying
assertion to watch for the appropriate event (e.g., 'worker:error') so the test
actually observes and asserts on emitted events.

---

81-110: テストアサーションが常に成功する（トートロジー）

maintenanceCompleted = true を await d.stop() の直後に設定し、その後 expect(maintenanceCompleted).toBe(true) でアサートしていますが、これは逐次実行されるため常に成功します。このアサーションはメンテナンスが実際に待機されたことを検証していません。

テストの価値は stop() がハングしないことを確認する点にありますが、アサーションが誤解を招く形になっています。

♻️ より意味のあるテストへの改善案

 it('stop() awaits in-flight idle maintenance before resolving', async () => {
-  let maintenanceCompleted = false
+  let maintenanceStarted = false
+  let stopResolved = false

   // Use retainRuns to ensure runIdleMaintenance does real work
   const d = createDurably({
     dialect: createDialect(),
     pollingIntervalMs: 50,
     retainRuns: '30d',
   })
   await d.migrate()

-  // Listen for the idle-maintenance cycle completing via worker:error
-  // or simply track that stop() doesn't resolve before maintenance
-  d.on('run:leased', () => {
-    // noop — just need the worker to process something
-  })
+  // Track idle maintenance via worker events if available
+  d.on('worker:error', () => {
+    // Maintenance errors would be emitted here
+  })

   d.start()

   // Let the worker go through at least one idle cycle
   // (processOne returns false → onIdle runs releaseExpiredLeases)
   await new Promise((r) => setTimeout(r, 150))
+  maintenanceStarted = true

   // stop() should await any in-flight maintenance
   await d.stop()
-  maintenanceCompleted = true
+  stopResolved = true

-  expect(maintenanceCompleted).toBe(true)
+  // Verify stop() resolved without hanging
+  expect(stopResolved).toBe(true)
+  expect(maintenanceStarted).toBe(true)
   await d.db.destroy()
 })

あるいは、テストの意図がより明確になるようにテスト名とコメントを調整することも検討してください：

it('stop() resolves without hanging when idle maintenance may be in-flight', async () => {

🤖 Prompt for AI Agents

Verify each finding against the current code and only fix it if needed.

In `@packages/durably/tests/shared/worker.shared.ts` around lines 81 - 110, The
test currently sets maintenanceCompleted = true immediately after awaiting
d.stop(), which makes the assertion tautological; instead, verify that stop()
awaited an in-flight maintenance by setting the flag from the actual maintenance
completion callback (e.g., inside whatever handler signals idle maintenance
completion such as the worker's maintenance callback or an emitted event like
'worker:error' or a custom 'maintenance:completed' listener) and then await
d.stop() before asserting the flag, or alternatively remove the redundant
flag/assertion and rename the test to something like "stop() resolves without
hanging when idle maintenance may be in-flight" to reflect the intent; update
references to maintenanceCompleted and the test name accordingly.